8a7f299aa946e92e8a0e0cb897d36491218a28ee,sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunnerTest.java,DataflowPipelineRunnerTest,testInvalidNumberOfWorkerHarnessThreads,#,644
Before Change
options.setProject("foo-12345");
options.setStagingLocation("gs://spam/ham/eggs");
options.setGcsUtil(buildMockGcsUtil(true /* bucket exists */));
options.as(DataflowPipelineDebugOptions.class).setNumberOfWorkerHarnessThreads(-1);
After Change
DataflowPipelineOptions options = PipelineOptionsFactory.as(DataflowPipelineOptions.class);
options.setRunner(DataflowPipelineRunner.class);
options.setProject("foo-12345");
options.setGcsUtil(mockGcsUtil);
options.setStagingLocation(VALID_GS_SPAM_HAM_EGGS);
options.as(DataflowPipelineDebugOptions.class).setNumberOfWorkerHarnessThreads(-1);